package cas.ihep.spark.loop;

import cas.ihep.spark.util.function.Function2;

public interface IterationServer<P,R>{
    @Deprecated
    default R broadcast(P values, R zero, Function2<R,R,R> aggregateFunc, Class<R> klass){
        return zero;
    }
    R broadcast(P values,R zero,Function2<R,R,R> agg);
}